//package com.zst.stream.message;
//
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.cloud.stream.messaging.Processor;
//import org.springframework.cloud.stream.messaging.Source;
//import org.springframework.messaging.support.MessageBuilder;
//import org.springframework.stereotype.Component;
//
//@Component
//public class SimpleSourceBean {
//    private Source source;
//
//    @Autowired
//    public SimpleSourceBean(Source source){
//        this.source = source;
//    }
//
//    public void publishMessage(String message){
//        System.out.println("Sending message to MicroServiceNodeOne: " + message);
//        StringMessage m = new StringMessage();
//        source.output().send(MessageBuilder.withPayload(m).build());
//    }
//}
